//package org.xqp.mq._01_hello;
//
//import com.rabbitmq.client.Channel;
//import com.rabbitmq.client.Connection;
//import com.rabbitmq.client.ConnectionFactory;
//
//import java.io.IOException;
//import java.util.concurrent.TimeoutException;
//
//
////生产者
//public class Producer {
//    //队列名hello
//    public static  final  String XQP_NAME_QUEUE ="XQP_NAME_QUEUE";
//    public static void main(String[] args) throws IOException, TimeoutException {
//        // 创建连接
//        ConnectionFactory factory = new ConnectionFactory();
//        Connection connection = factory.newConnection();
//        // 创建通道
//        Channel channel = connection.createChannel();
//        // 创建队列
//        channel.queueDeclare(XQP_NAME_QUEUE, // 队列的名字
//                true , // 队列是否持久化
//                false,// 队列是否独占连接
//                false ,// 用完是否删除队列
//                null);// 有没有其他配置
//        // 发送消息
//        channel.basicPublish("",// 使用默认的交换机
//                XQP_NAME_QUEUE , // 队列的名字
//                null, // 其他参数
//                "接收到了吗".getBytes());
//        System.out.println("消息已发送");
//    }
//}
